72551def07b123598cd739ab474ac2844ae9daea,presto-main/src/main/java/com/facebook/presto/sql/planner/LocalExecutionPlanner.java,LocalExecutionPlanner,plan,#Session#PlanNode#List#Map#OutputFactory#,368
Before Change
.map(types::get)
.collect(toImmutableList());
DriverFactory driverFactory = new DriverFactory(
context.isInputDriver(),
true,
ImmutableList.<OperatorFactory>builder()
.addAll(physicalOperation.getOperatorFactories())
.add(outputOperatorFactory.createOutputOperator(
context.getNextOperatorId(),
plan.getId(),
outputTypes,
pagePreprocessor,
new PagesSerdeFactory(blockEncodingSerde, isExchangeCompressionEnabled(session))))
.build(),
context.getDriverInstanceCount());
context.addDriverFactory(driverFactory);
addLookupOuterDrivers(context);
After Change
.map(types::get)
.collect(toImmutableList());
context.addDriverFactory(context.isInputDriver(),
true,
ImmutableList.<OperatorFactory>builder()
.addAll(physicalOperation.getOperatorFactories())
.add(outputOperatorFactory.createOutputOperator(
context.getNextOperatorId(),
plan.getId(),
outputTypes,
pagePreprocessor,
new PagesSerdeFactory(blockEncodingSerde, isExchangeCompressionEnabled(session))))
.build(),
context.getDriverInstanceCount());
addLookupOuterDrivers(context);